//package com.ytjj.qmyx.mall.kafka;
//
//import org.springframework.cloud.stream.annotation.Output;
//import org.springframework.messaging.MessageChannel;
//
//public interface IProductStatisticsKafkaOut {
//    String PRODUCT_KAFKA_OUT="output-product";
//    String PRODUCT_HISTORY_OUT = "new_product";
//
//    @Output(PRODUCT_KAFKA_OUT)
//    MessageChannel output();
//
//    @Output(PRODUCT_HISTORY_OUT)
//    MessageChannel historyOutput();
//}
